#pragma once
#include <muduo/net/EventLoopThread.h>
#include <mqcomm/threadpool.hpp>
#include <iostream>
#include <memory>   
using namespace std;

namespace rbmq {
    // 异步工作线程
    class AsyncWorker {
    public :
        AsyncWorker()
            :_loopthread()
            ,_threadpool()
        {

        }
        typedef shared_ptr<AsyncWorker> ptr;
        muduo::net::EventLoopThread _loopthread;
        threadpool _threadpool;

    };

};